package org.com.blbl.sortHotTopicTop5;

import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Reducer;
import org.com.blbl.bean.BiliSortBean;

import java.io.IOException;

public class SortHotTopicTop5Reducer extends Reducer<BiliSortBean, Text, Text, BiliSortBean> {

    private int count = 0;//计数器
    //BiliSortBean key: 当前处理的键，表示某个热门话题的排序信息。
    //Iterable<Text> values: 与该热门话题相关的所有值，通常是话题的名称或其他属性。
    @Override
    protected void reduce(BiliSortBean key, Iterable<Text> values, Context context) throws IOException, InterruptedException {
        // 检查是否已经输出了10个结果
        if (count < 10) {
            //values.iterator().next() 从 values 中获取第一个 Text 值（通常是热门话题的名称或其他信息）
            Text outValue = values.iterator().next();
            //使用 context.write(outValue, key) 将获取的 outValue 作为输出的键，将 key（即 BiliSortBean 类型的排序信息）作为输出的值。
            context.write(outValue, key);
            count ++;
        }

    }

}
